package com.zhao.biz.tag.perform

import org.apache.spark.sql.Row

/**
 * Description: 地域标签<br/>
 * Copyright (c) ，2021 ， 赵 <br/>
 * A wet person does not fear the rain. <br/>
 * Date： 2021/1/14 15:19
 * 地域标签(省标签格式: ZPxxx ->1, 地市标签格式: ZCxxx->1) xxx为生或式名称
 *
 * @author 柒柒
 * @version : 1.0
 */

object TagsLocation extends IMakeTags {
  /**
   * 数据标签接口
   *
   * @param args
   * @return
   */
  override def makeTags(args: Any*): List[(String, Int)] = {

    var list: List[(String, Int)] = List[(String, Int)]()

    val row: Row = args(0).asInstanceOf[Row]

    //获得省份名
    val provincename = row.getAs[String]("provincename")
    list :+= ("ZP" + provincename,1)

    //获得城市名
    val cityname = row.getAs[String]("cityname")
    list :+= ("ZC" + cityname,1)

    list
  }
}












